package com.wang.streamx;

import com.streamxhub.streamx.flink.core.TableContext;
import com.streamxhub.streamx.flink.core.TableEnvConfig;
import com.streamxhub.streamx.flink.core.TableEnvConfigFunction;
import org.apache.flink.api.java.utils.ParameterTool;
import org.apache.flink.table.api.TableConfig;

public class JavaFlinkSqlJob {

    public static void main(String[] args) {

        TableEnvConfig tableEnvConfig = new TableEnvConfig(args, (tableConfig, parameterTool) -> {
            System.out.println("set tableConfig...");
        });

        TableContext context = new TableContext(tableEnvConfig);
        context.sql("flinksql");


    }
}
